#include <time.h>
#include <windows.h>
#include "Condition.h"
#include "Lock.h"
#if defined(_MSC_VER) || defined(_MSC_EXTENSIONS)
  #define DELTA_EPOCH_IN_MICROSECS  11644473600000000Ui64
#else
  #define DELTA_EPOCH_IN_MICROSECS  11644473600000000ULL
#endif
 
struct timezone 
{
  int  tz_minuteswest; /* minutes W of Greenwich */
  int  tz_dsttime;     /* type of dst correction */
};
 
int gettimeofday(struct timeval *tv, struct timezone *tz)
{
  FILETIME ft;
  unsigned __int64 tmpres = 0;
  static int tzflag;
 
  if (NULL != tv)
  {
	GetSystemTimeAsFileTime(&ft);
 
	tmpres |= ft.dwHighDateTime;
	tmpres <<= 32;
	tmpres |= ft.dwLowDateTime;
 
	/*converting file time to unix epoch*/
	tmpres /= 10;  /*convert into microseconds*/
	tmpres -= DELTA_EPOCH_IN_MICROSECS; 
	tv->tv_sec = (long)(tmpres / 1000000UL);
	tv->tv_usec = (long)(tmpres % 1000000UL);
  }
 
  if (NULL != tz)
  {
	if (!tzflag)
	{
	  _tzset();
	  tzflag++;
	}
	tz->tz_minuteswest = _timezone / 60;
	tz->tz_dsttime = _daylight;
  }
 
  return 0;
}

Condition::Condition() {
  pthread_cond_init(&mCondition, NULL);
}

void Condition::wait(Lock *lock) {
  pthread_cond_wait(&mCondition, &lock->mMutex);
}

void Condition::signal() {
	pthread_cond_signal(&mCondition);
}

void Condition::broadcast() {
  pthread_cond_broadcast(&mCondition);
}

/**
 *  Returns true if signal occured and false if wait timed out.
 */
bool Condition::timedWait(Lock *lock, int seconds) {
  timeval now;
  timespec timeout;
  gettimeofday(&now, NULL);
  timeout.tv_sec = now.tv_sec + seconds;
  timeout.tv_nsec = now.tv_usec * 1000;
  return pthread_cond_timedwait(&mCondition, &lock->mMutex, &timeout) == 0;
}
